package com.tvunetworks.center.device.schedule;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

/**
 *
 * @author lebronchen
 * 项目名：tvucc-device
 * 类名：SyncTvuDeviceTimer
 * 描述:TODO<p>同步sychdevice数据进入tvu_device表</p>
 * 创建人：Gabrielliu(lk)
 * 创建时间：2020年3月25日 下午5:23:01   
 * 修改人：   
 * 修改时间：   
 * 修改备注：  
 * @version v1.0   
 *
 */
@Slf4j
@Component
public class SyncTvuDeviceTimer {
	
//	@Autowired
//	SyncTvuDeviceMapper syncTvuDeviceMapper;
//
//	//执行任务
//	//@Scheduled(fixedRate  = 10000)
//	@Scheduled(fixedDelay = 10000)
//	public void syncTvuDeviceTask(){
//         //1.查询出token device表中存在而tvu_device表不存在的数据
//		 List<String> notExistTvuDeviceData = syncTvuDeviceMapper.getNotExistTvuDeviceData();
//		 log.info(">>>>>>>>>>>>>>>>>get notExistTvuDeviceData size:{}",notExistTvuDeviceData.size());
//		 if(notExistTvuDeviceData == null || notExistTvuDeviceData.size() == 0){
//			 return;
//		 }
//		 //2.取出peerId，判断sychdevice表是否存在，存在即更新，不存在，不做操作
//		 for(int i = 0 ; i < notExistTvuDeviceData.size() ; i++){
//			 String peerId = notExistTvuDeviceData.get(i);
//			 if(StringUtils.isBlank(peerId)){
//				 continue;
//			 }
//			 //3.查询sychdevice表
////			 int getSychdeviceData = syncTvuDeviceMapper.selectSychdeviceByPeerId(peerId);
////			 //不存在,不操作
////			 if(getSychdeviceData == 0){
////					log.error(">>>>>>>>>>>>>>>>>>>>>>>>synchdevice not exist peerId:{}",peerId);
////				 continue;
////			 }
//			int updateFlag = syncTvuDeviceMapper.updateToTvuDevice(peerId);
//			log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>synchdevice exists peerId:{} update",peerId);
//			if(updateFlag == 0){
//				log.info("peerId：{} update failed",peerId);
//			}
//			//线程休眠
//			try {
//				Thread.sleep(1000);
//			} catch (InterruptedException e) {
//				log.error("InterruptedException is error",e);
//			}
//		 }
//
//
//	}

}
